package com.cloud.message.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.cloud.common.bean.PageInfo;
import com.cloud.message.dto.PendingQueryParamDTO;
import com.cloud.message.entity.MessagePending;
import com.cloud.message.rocketmq.MQMessage;

public interface MessagePendingService extends IService<MessagePending> {

    void createPending(String serviceName, MQMessage message);

    void removePending(String serviceName, String topic);

    void handleRetry();

    PageInfo<MessagePending> getPage(PendingQueryParamDTO pendingQueryParamDTO);

}
